﻿using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Furion.EventBus.RabbitMq
{
    public class RabbitMqEventSource : IEventSource
    {
        public string EventId { get; }

        public object Payload { get; }

        public DateTime CreatedTime { get; }

        public CancellationToken CancellationToken { get; }

        public RabbitMqEventSource(string queueName, string payload)
        {
            EventId = queueName;
            Payload = payload;
            CreatedTime = DateTime.Now;
            CancellationToken = new CancellationToken(false);

        }
    }
}
